package com.yequan.rocketmq.service;

import org.apache.rocketmq.client.exception.MQBrokerException;
import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.remoting.exception.RemotingException;

import java.io.UnsupportedEncodingException;

/**
 * @author yq
 * @date 2020/09/10
 */
public interface RocketMQService {

    void sendMessage(String topic, String tag, byte[] body) throws InterruptedException, RemotingException, MQClientException, MQBrokerException;

    void sendMessage(String topic, String tag, String msg) throws InterruptedException, RemotingException, MQClientException, MQBrokerException, UnsupportedEncodingException;

    void sendMessage(String topic, String tag, Object msgObj) throws InterruptedException, RemotingException, MQClientException, MQBrokerException, UnsupportedEncodingException;

}
